package com.lyy.worker;

import com.lyy.utils.RabbitMqUtils;
import com.rabbitmq.client.Channel;

/**
 * @author liyuanyao
 */
public class handConsumer {
    public static final String ACK_QUEUE_NAME ="ack_queue";

    public static void main(String[] args)throws Exception {
        Channel channel = RabbitMqUtils.getChannel();
        //声明队列
        channel.queueDeclare(ACK_QUEUE_NAME,false,false,false,null);
        


    }
}
